package com.example.service.impl.kafka.listener;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class kaListener {

    @KafkaListener(topics = "test")
    public void aa(ConsumerRecord<String,String> consumerRecord){
        System.out.println("消费者："+consumerRecord.value());
        System.out.println(consumerRecord);
    }
}
